package ken.spring.cloud.alibaba;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * <ul>
 * <li>Title: MySink</li>
 * <li>Description: TODO </li>
 * </ul>
 *
 * @author swc
 * @date 2022-07-07 16:13
 */
//@Component
public interface MySink {
    @Input("msgInput1")
    SubscribableChannel msgInput1();

    @Input("msgTransactionalInput2")
    SubscribableChannel msgTransactionalInput2();
}
